package com.ctsi.canal.starter.config.properties;

import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

/**
 * kafka连接配置类
 *
 * @author anank
 */
@ConfigurationProperties(prefix = KafkaCanalProperties.CANAL_PREFIX)
@Configuration
public class KafkaCanalProperties extends CanalProperties {

    private Integer partition;

    private String groupId;

    public Integer getPartition() {
        return partition;
    }

    public void setPartition(Integer partition) {
        this.partition = partition;
    }

    public String getGroupId() {
        return groupId;
    }

    public void setGroupId(String groupId) {
        this.groupId = groupId;
    }
}
